﻿namespace TestApp.DataService
{
    using System;
    using System.Collections.Generic;
    using System.Reactive;
    using Contracts;
    using JetBrains.Annotations;

    internal interface IDataAggregator : IDisposable
    {
        [NotNull] IObservable<Unit> CreateHasNewEntitySource();

        bool TryGetEntities(long version, out long dataVersion, out IEnumerable<EntityDto> entities);
    }
}